package atomlist;

import java.util.Random;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;


/**
 * @功能
 * @创建时间 2019/12/21
 */
public class T06_ArrayBlockingQueue {
    static BlockingQueue<String> strs = new ArrayBlockingQueue<>(10); //最多装10个，有界队列
    static Random r= new Random();

    public static void main(String[] args) throws InterruptedException {
        for(int i=0;i<10;i++) {
        strs.put("a"+i);
        }
  //         strs.put("aaa"); //满了会等待，程序阻塞
  //         strs.add("aaa"); // 会抛异常
             strs.offer("aaa"); //会返回布尔类型
  //         strs.offer("aaa",1, TimeUnit.SECONDS); //加的时间，到达时间就不加，这是加一秒，没成功就不加
            System.out.println(strs);

    }
}
